package org.chnxi.study.messagequeue.kafka.comsumer;

import org.apache.kafka.clients.consumer.KafkaConsumer;
import org.apache.kafka.common.TopicPartition;

import java.util.Map;

public interface OffsetProcessor<K,V> {

    public void setKafkaConsumer(KafkaConsumer<K,V> consumer);

    public void resetOffset();

    public void saveOffSet(Map<TopicPartition, Long> offset);

}
